🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / core / data / src / commonMain / kotlin / org / meshtastic / core / data / repository / PacketRepositoryImpl.kt
Displaying Raw • Download
core/data/src/commonMain/kotlin/org/meshtastic/core/data/repository/PacketRepositoryImpl.kt dda971b5ce81ed5dd9549dbaba1d8548bbfa4126 (dda971b5) Text, 21.75 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.repository
Tff7b72import T7ee787androidx.paging.Pager
Tff7b72import T7ee787androidx.paging.PagingConfig
Tff7b72import T7ee787androidx.paging.PagingData
Tff7b72import T7ee787androidx.paging.map
Tff7b72import T7ee787kotlinx.coroutines.NonCancellable
Tff7b72import T7ee787kotlinx.coroutines.flow.Flow
Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf
Tff7b72import T7ee787kotlinx.coroutines.flow.map
Tff7b72import T7ee787kotlinx.coroutines.flow.mapLatest
Tff7b72import T7ee787kotlinx.coroutines.withContext
Tff7b72import T7ee787okio.ByteString.Companion.toByteString
Tff7b72import T7ee787org.koin.core.annotation.Single
Tff7b72import T7ee787org.meshtastic.core.database.DatabaseProvider
Tff7b72import T7ee787org.meshtastic.core.database.dao.NodeInfoDao
Tff7b72import T7ee787org.meshtastic.core.database.entity.PacketEntity
Tff7b72import T7ee787org.meshtastic.core.database.entity.toReaction
Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers
Tff7b72import T7ee787org.meshtastic.core.model.ContactSettings
Tff7b72import T7ee787org.meshtastic.core.model.DataPacket
Tff7b72import T7ee787org.meshtastic.core.model.Message
Tff7b72import T7ee787org.meshtastic.core.model.MessageStatus
Tff7b72import T7ee787org.meshtastic.core.model.Node
Tff7b72import T7ee787org.meshtastic.core.model.NodeAddress
Tff7b72import T7ee787org.meshtastic.core.model.Reaction
Tff7b72import T7ee787org.meshtastic.proto.ChannelSettings
Tff7b72import T7ee787org.meshtastic.proto.PortNum
Tff7b72import T7ee787org.meshtastic.core.database.entity.ContactSettings Tff7b72as Te6edf3ContactSettingsEntity
Tff7b72import T7ee787org.meshtastic.core.database.entity.Packet Tff7b72as Te6edf3RoomPacket
Tff7b72import T7ee787org.meshtastic.core.database.entity.ReactionEntity Tff7b72as Te6edf3RoomReaction
Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository Tff7b72as Te6edf3SharedPacketRepository
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4)
Tf0883e@Single
Tff7b72class T56d364PacketRepositoryImplTb4b4b4(Tff7b72private Tff7b72val Te6edf3dbManagerTb4b4b4: Te6edf3DatabaseProviderTb4b4b4, Tff7b72private Tff7b72val Te6edf3dispatchersTb4b4b4: Te6edf3CoroutineDispatchersTb4b4b4) Tb4b4b4:
Te6edf3SharedPacketRepository Tb4b4b4{
Tff7b72override Tff7b72fun Td2a8ffgetWaypointsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72>Tff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllWaypointsFlowTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetContactsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3MapTff7b72<Tffa657StringTb4b4b4, Te6edf3DataPacketTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager
Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactKeysTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3map Tff7b72-Tff7b72> Te6edf3mapTb4b4b4.Te6edf3mapValues Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetContactsPagedTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3PairTff7b72<Tffa657StringTb4b4b4, Te6edf3DataPacketTff7b72>Tff7b72>Tff7b72> Tff7b72= Te6edf3PagerTb4b4b4(
Te6edf3config Tff7b72=
Te6edf3PagingConfigTb4b4b4(
Te6edf3pageSize Tff7b72= Te6edf3CONTACTS_PAGE_SIZETb4b4b4,
Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3initialLoadSize Tff7b72= Te6edf3CONTACTS_PAGE_SIZETb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactKeysPagedTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4.Te6edf3flow
Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72> Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3contact_key Te6edf3to Tffa657itTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetMessageCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessageCountTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetUnreadCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetUnreadCountFlowTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountFlowTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetFirstUnreadMessageUuidTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657Long?Tff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFirstUnreadMessageUuidTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffhasUnreadMessagesTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657BooleanTff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3hasUnreadMessagesTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetUnreadCountTotalTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountTotalTb4b4b4(Tb4b4b4) Tb4b4b4}
T8b949e// One-shot writes go through withDb so they register with the cross-transport merge drain barrier. The callback
T8b949e// is never replayed after it starts; callers needing retries must make that policy explicit where idempotency is
T8b949e// known. Reads and Flow/Paging factories stay on currentDb by design.
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearUnreadCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3timestampTb4b4b4: Tffa657LongTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3io Tff7b72+ Te6edf3NonCancellableTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3clearUnreadCountTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3timestampTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearAllUnreadCountsTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3io Tff7b72+ Te6edf3NonCancellableTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3clearAllUnreadCountsTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateLastReadMessageTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3messageUuidTb4b4b4: Tffa657LongTb4b4b4, Te6edf3lastReadTimestampTb4b4b4: Tffa657LongTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3io Tff7b72+ Te6edf3NonCancellableTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateLastReadMessageTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3messageUuidTb4b4b4, Te6edf3lastReadTimestampTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetQueuedPacketsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllDataPacketsTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3QUEUED Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetEnroutePacketsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllDataPacketsTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3ENROUTE Tb4b4b4}
Tb4b4b4}
T8b949e// A null from withDb means no database was available, so nothing was timed out.
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8fftimeOutEnroutePacketTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4, Te6edf3routingErrorTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3timeOutEnroutePacketTb4b4b4(Te6edf3packetIdTb4b4b4, Te6edf3routingErrorTb4b4b4) Tb4b4b4} Tff7b72?: Tff7b72false
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffinsertRoomPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3io Tff7b72+ Te6edf3NonCancellableTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsavePacketTb4b4b4(
Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4,
Te6edf3receivedTimeTb4b4b4: Tffa657LongTb4b4b4,
Te6edf3readTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4,
Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3packetToSave Tff7b72=
Te6edf3RoomPacketTb4b4b4(
Te6edf3uuid Tff7b72= T79c0ff0LTb4b4b4,
Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4,
Te6edf3port_num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4,
Te6edf3contact_key Tff7b72= Te6edf3contactKeyTb4b4b4,
Te6edf3received_time Tff7b72= Te6edf3receivedTimeTb4b4b4,
Te6edf3read Tff7b72= Te6edf3readTb4b4b4,
Te6edf3data Tff7b72= Te6edf3packetTb4b4b4,
Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3snrTb4b4b4,
Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rssiTb4b4b4,
Te6edf3hopsAway Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hopsAwayTb4b4b4,
Te6edf3filtered Tff7b72= Te6edf3filteredTb4b4b4,
Te6edf3messageText Tff7b72= Te6edf3packetTb4b4b4.Te6edf3textTb4b4b4.Te6edf3orEmptyTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3insertRoomPacketTb4b4b4(Te6edf3packetToSaveTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetMessagesFromTb4b4b4(
Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3limitTb4b4b4: Tffa657Int?Tb4b4b4,
Te6edf3includeFilteredTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3flow Tff7b72=
Tff7b72when Tb4b4b4{
Te6edf3limit Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3limitTb4b4b4)
Tff7b72!Te6edf3includeFiltered Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3includeFiltered Tff7b72= Tff7b72falseTb4b4b4)
Tff7b72else Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4)
Tb4b4b4}
Te6edf3flowTb4b4b4.Te6edf3mapLatest Tb4b4b4{ Te6edf3packets Tff7b72-Tff7b72>
Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)
Tff7b72val Te6edf3replyIds Tff7b72= Te6edf3packetsTb4b4b4.Te6edf3mapNotNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3id Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4} Tb4b4b4}Tb4b4b4.Te6edf3distinctTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3replyMap Tff7b72= Te6edf3batchGetPacketsByIdsTb4b4b4(Te6edf3replyIdsTb4b4b4)
Te6edf3packetsTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>
Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}
Tff7b72val Te6edf3originalMessage Tff7b72= Te6edf3replyIdTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3replyMapTff7b72[Tffa657itTff7b72] Tb4b4b4}Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetMessagesFromPagedTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72=
Te6edf3PagerTb4b4b4(
Te6edf3config Tff7b72=
Te6edf3PagingConfigTb4b4b4(
Te6edf3pageSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,
Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3initialLoadSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessagesFromPagedTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4.Te6edf3flow
Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72>
Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)
Tff7b72val Te6edf3replyCache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntity?Tff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>
Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}
Tff7b72val Te6edf3originalMessage Tff7b72=
Te6edf3replyId
Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3replyCacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getPacketByPacketIdInternalTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}
Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetMessagesFromPagedTb4b4b4(
Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3includeFilteredTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72= Te6edf3PagerTb4b4b4(
Te6edf3config Tff7b72=
Te6edf3PagingConfigTb4b4b4(
Te6edf3pageSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,
Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,
Te6edf3initialLoadSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessagesFromPagedTb4b4b4(Te6edf3contactKeyTb4b4b4, Te6edf3includeFilteredTb4b4b4)
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4.Te6edf3flow
Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72>
Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)
Tff7b72val Te6edf3replyCache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntity?Tff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>
Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}
Tff7b72val Te6edf3originalMessage Tff7b72=
Te6edf3replyId
Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3replyCacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getPacketByPacketIdInternalTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}
Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateMessageStatusTb4b4b4(Te6edf3dTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3mTb4b4b4: Te6edf3MessageStatusTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateMessageStatusTb4b4b4(Te6edf3dTb4b4b4, Te6edf3mTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateMessageIdTb4b4b4(Te6edf3dTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3idTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateMessageIdTb4b4b4(Te6edf3dTb4b4b4, Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetMessageTranslationTb4b4b4(Te6edf3uuidTb4b4b4: Tffa657LongTb4b4b4, Te6edf3translatedTextTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setTranslationTb4b4b4(Te6edf3uuidTb4b4b4, Te6edf3translatedTextTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetShowTranslatedTb4b4b4(Te6edf3uuidTb4b4b4: Tffa657LongTb4b4b4, Te6edf3showTranslatedTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setShowTranslatedTb4b4b4(Te6edf3uuidTb4b4b4, Te6edf3showTranslatedTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByIdTb4b4b4(Te6edf3idTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3DataPacket? Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByIdTb4b4b4(Te6edf3idTb4b4b4)Tff7b72?.Te6edf3data Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3DataPacket? Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tff7b72?.Te6edf3packetTff7b72?.Te6edf3data
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByPacketIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4) Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffbatchGetPacketsByIdsTb4b4b4(Te6edf3idsTb4b4b4: Te6edf3ListTff7b72<Tffa657IntTff7b72>Tb4b4b4)Tb4b4b4: Te6edf3MapTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntityTff7b72> Tff7b72= Tff7b72if Tb4b4b4(Te6edf3idsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3emptyMapTb4b4b4(Tb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)
Te6edf3idsTb4b4b4.Te6edf3chunkedTb4b4b4(Te6edf3NodeInfoDaoTb4b4b4.Te6edf3MAX_BIND_PARAMSTb4b4b4)
Tb4b4b4.Te6edf3flatMap Tb4b4b4{ Te6edf3daoTb4b4b4.Te6edf3getPacketsByPacketIdsTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3associateBy Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetTb4b4b4.Te6edf3packetId Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffmemoizeTb4b4b4(Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4)Tb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3Node Tb4b4b4{
Tff7b72val Te6edf3cache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657String?Tb4b4b4, Te6edf3NodeTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72return Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3cacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getNodeTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertTb4b4b4(
Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4,
Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3receivedTimeTb4b4b4: Tffa657LongTb4b4b4,
Te6edf3readTb4b4b4: Tffa657BooleanTb4b4b4,
Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4,
Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3packetToSave Tff7b72=
Te6edf3RoomPacketTb4b4b4(
Te6edf3uuid Tff7b72= T79c0ff0LTb4b4b4,
Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4,
Te6edf3port_num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4,
Te6edf3contact_key Tff7b72= Te6edf3contactKeyTb4b4b4,
Te6edf3received_time Tff7b72= Te6edf3receivedTimeTb4b4b4,
Te6edf3read Tff7b72= Te6edf3readTb4b4b4,
Te6edf3data Tff7b72= Te6edf3packetTb4b4b4,
Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3snrTb4b4b4,
Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rssiTb4b4b4,
Te6edf3hopsAway Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hopsAwayTb4b4b4,
Te6edf3filtered Tff7b72= Te6edf3filteredTb4b4b4,
Te6edf3messageText Tff7b72= Te6edf3packetTb4b4b4.Te6edf3textTb4b4b4.Te6edf3orEmptyTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3insertRoomPacketTb4b4b4(Te6edf3packetToSaveTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3routingErrorTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Unit Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updatePacketByKeyTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3routingErrorTb4b4b4) Tb4b4b4} Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3ReactionTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3toEntityTb4b4b4(Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3ReactionTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateReactionByKeyTb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3toEntityTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetReactionByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3Reaction? Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getReactionByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tff7b72?.Te6edf3toReaction Tb4b4b4{ Tff7b72null Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8fffindPacketsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findPacketsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3data Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8fffindReactionsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3ReactionTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findReactionsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tb4b4b4.Te6edf3toReaction Tb4b4b4{ Tff7b72null Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateSFPPStatusTb4b4b4(
Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3toTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3hashTb4b4b4: Te6edf3ByteArrayTb4b4b4,
Te6edf3statusTb4b4b4: Te6edf3MessageStatusTb4b4b4,
Te6edf3rxTimeTb4b4b4: Tffa657LongTb4b4b4,
Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4,
Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{
Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3applySFPPStatusTb4b4b4(Te6edf3packetIdTb4b4b4, Te6edf3fromTb4b4b4, Te6edf3toTb4b4b4, Te6edf3hashTb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3statusTb4b4b4, Te6edf3rxTimeTb4b4b4, Te6edf3myNodeNumTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateSFPPStatusByHashTb4b4b4(Te6edf3hashTb4b4b4: Te6edf3ByteArrayTb4b4b4, Te6edf3statusTb4b4b4: Te6edf3MessageStatusTb4b4b4, Te6edf3rxTimeTb4b4b4: Tffa657LongTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3applySFPPStatusByHashTb4b4b4(Te6edf3hashTb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3statusTb4b4b4, Te6edf3rxTimeTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteMessagesTb4b4b4(Te6edf3uuidListTb4b4b4: Te6edf3ListTff7b72<Tffa657LongTff7b72>Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteMessagesAtomicTb4b4b4(Te6edf3uuidListTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteContactsTb4b4b4(Te6edf3contactListTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteContactsTb4b4b4(Te6edf3contactListTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteWaypointTb4b4b4(Te6edf3idTb4b4b4: Tffa657IntTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteWaypointTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffdeleteTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffupdateTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetContactSettingsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3MapTff7b72<Tffa657StringTb4b4b4, Te6edf3ContactSettingsTff7b72>Tff7b72> Tff7b72= Te6edf3dbManager
Tb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactSettingsTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3map Tff7b72-Tff7b72> Te6edf3mapTb4b4b4.Te6edf3mapValues Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3toSharedTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetContactSettingsTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3ContactSettings Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactSettingsTb4b4b4(Te6edf3contactTb4b4b4)Tff7b72?.Te6edf3toSharedTb4b4b4(Tb4b4b4) Tff7b72?: Te6edf3ContactSettingsTb4b4b4(Te6edf3contactTb4b4b4)
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetMuteUntilTb4b4b4(Te6edf3contactsTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4, Te6edf3untilTb4b4b4: Tffa657LongTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setMuteUntilTb4b4b4(Te6edf3contactsTb4b4b4, Te6edf3untilTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffinsertReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3RoomReactionTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3reactionTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffupdateReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3RoomReactionTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateTb4b4b4(Te6edf3reactionTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72fun Td2a8ffgetFilteredCountFlowTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=
Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFilteredCountFlowTb4b4b4(Te6edf3contactKeyTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetFilteredCountTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFilteredCountTb4b4b4(Te6edf3contactKeyTb4b4b4) Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetContactFilteringDisabledTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4, Te6edf3disabledTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setContactFilteringDisabledTb4b4b4(Te6edf3contactKeyTb4b4b4, Te6edf3disabledTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearPacketDBTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteAllTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffmigrateChannelsByPSKTb4b4b4(Te6edf3oldSettingsTb4b4b4: Te6edf3ListTff7b72<Te6edf3ChannelSettingsTff7b72>Tb4b4b4, Te6edf3newSettingsTb4b4b4: Te6edf3ListTff7b72<Te6edf3ChannelSettingsTff7b72>Tb4b4b4) Tb4b4b4{
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{
Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3migrateChannelsByPSKTb4b4b4(Te6edf3oldSettingsTb4b4b4, Te6edf3newSettingsTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateFilteredBySenderTb4b4b4(Te6edf3senderIdTb4b4b4: Tffa657StringTb4b4b4, Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3pattern Tff7b72= Ta5d6ff"Ta5d6ff%Ta5d6ff\"Ta5d6fffromTa5d6ff\"Ta5d6ff:Ta5d6ff\"Tffd700${Te6edf3senderIdTffd700}Ta5d6ff\"Ta5d6ff%Ta5d6ff"
Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3withDb Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateFilteredBySenderTb4b4b4(Te6edf3patternTb4b4b4, Te6edf3filteredTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72fun Te6edf3orgTb4b4b4.Td2a8ffmeshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3databaseTb4b4b4.Te6edf3daoTb4b4b4.Te6edf3PacketDaoTb4b4b4.Te6edf3getAllWaypointsFlowTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3RoomPacketTff7b72>Tff7b72> Tff7b72=
Te6edf3getAllPacketsTb4b4b4(Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APPTb4b4b4.Te6edf3valueTb4b4b4)
Tff7b72private Tff7b72fun Te6edf3ContactSettingsEntityTb4b4b4.Td2a8fftoSharedTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3ContactSettingsTb4b4b4(
Te6edf3contactKey Tff7b72= Te6edf3contact_keyTb4b4b4,
Te6edf3muteUntil Tff7b72= Te6edf3muteUntilTb4b4b4,
Te6edf3lastReadMessageUuid Tff7b72= Te6edf3lastReadMessageUuidTb4b4b4,
Te6edf3lastReadMessageTimestamp Tff7b72= Te6edf3lastReadMessageTimestampTb4b4b4,
Te6edf3filteringDisabled Tff7b72= Te6edf3filteringDisabledTb4b4b4,
Te6edf3isMuted Tff7b72= Te6edf3isMutedTb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72fun Te6edf3ReactionTb4b4b4.Td2a8fftoEntityTb4b4b4(Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3RoomReactionTb4b4b4(
Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3replyId Tff7b72= Te6edf3replyIdTb4b4b4,
Te6edf3userId Tff7b72= Te6edf3userTb4b4b4.Te6edf3idTb4b4b4,
Te6edf3emoji Tff7b72= Te6edf3emojiTb4b4b4,
Te6edf3timestamp Tff7b72= Te6edf3timestampTb4b4b4,
Te6edf3snr Tff7b72= Te6edf3snrTb4b4b4,
Te6edf3rssi Tff7b72= Te6edf3rssiTb4b4b4,
Te6edf3hopsAway Tff7b72= Te6edf3hopsAwayTb4b4b4,
Te6edf3packetId Tff7b72= Te6edf3packetIdTb4b4b4,
Te6edf3status Tff7b72= Te6edf3statusTb4b4b4,
Te6edf3routingError Tff7b72= Te6edf3routingErrorTb4b4b4,
Te6edf3relays Tff7b72= Te6edf3relaysTb4b4b4,
Te6edf3relayNode Tff7b72= Te6edf3relayNodeTb4b4b4,
Te6edf3to Tff7b72= Te6edf3toTb4b4b4,
Te6edf3channel Tff7b72= Te6edf3channelTb4b4b4,
Te6edf3sfpp_hash Tff7b72= Te6edf3sfppHashTb4b4b4,
Tb4b4b4)
Tff7b72override Tff7b72fun Td2a8ffsearchMessagesTb4b4b4(Te6edf3queryTb4b4b4: Tffa657StringTb4b4b4, Te6edf3contactKeyTb4b4b4: Tffa657String?Tb4b4b4, Te6edf3getNodeTb4b4b4: Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tb4b4b4{
Tff7b72val Te6edf3sanitized Tff7b72= Te6edf3sanitizeFtsQueryTb4b4b4(Te6edf3queryTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3sanitizedTb4b4b4.Te6edf3isBlankTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72return Te6edf3flowOfTb4b4b4(Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72return Te6edf3dbManagerTb4b4b4.Te6edf3observeCurrentDb Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72>
Te6edf3kotlinxTb4b4b4.Te6edf3coroutinesTb4b4b4.Te6edf3flowTb4b4b4.Te6edf3flow Tb4b4b4{
Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3packets Tff7b72=
Tff7b72if Tb4b4b4(Te6edf3contactKey Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3daoTb4b4b4.Te6edf3searchMessagesInConversationTb4b4b4(Te6edf3sanitizedTb4b4b4, Te6edf3contactKeyTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3daoTb4b4b4.Te6edf3searchMessagesTb4b4b4(Te6edf3sanitizedTb4b4b4)
Tb4b4b4}
Te6edf3emitTb4b4b4(
Te6edf3packetsTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>
Tff7b72val Te6edf3node Tff7b72= Te6edf3getNodeTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3fromTb4b4b4)
Tff7b72val Te6edf3isFromLocal Tff7b72=
Te6edf3nodeTb4b4b4.Te6edf3userTb4b4b4.Te6edf3id Tff7b72=Tff7b72= Te6edf3NodeAddressTb4b4b4.Te6edf3ID_LOCAL Tff7b72|Tff7b72|
Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3myNodeNum Tff7b72!Tff7b72= T79c0ff0 Tff7b72&Tff7b72& Te6edf3nodeTb4b4b4.Te6edf3num Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3myNodeNumTb4b4b4)
Te6edf3MessageTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3packetTb4b4b4.Te6edf3uuidTb4b4b4,
Te6edf3receivedTime Tff7b72= Te6edf3packetTb4b4b4.Te6edf3received_timeTb4b4b4,
Te6edf3node Tff7b72= Te6edf3nodeTb4b4b4,
Te6edf3text Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3textTb4b4b4.Te6edf3orEmptyTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3fromLocal Tff7b72= Te6edf3isFromLocalTb4b4b4,
Te6edf3meshTime Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3timeTb4b4b4,
Te6edf3time Tff7b72=
Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3modelTb4b4b4.Te6edf3utilTb4b4b4.Te6edf3getShortDateTimeTb4b4b4(
Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3timeTb4b4b4.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72> T79c0ff0 Tb4b4b4} Tff7b72?: Te6edf3packetTb4b4b4.Te6edf3received_timeTb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3snrTb4b4b4,
Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rssiTb4b4b4,
Te6edf3hopsAway Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hopsAwayTb4b4b4,
Te6edf3read Tff7b72= Te6edf3packetTb4b4b4.Te6edf3readTb4b4b4,
Te6edf3status Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3statusTb4b4b4,
Te6edf3routingError Tff7b72= Te6edf3packetTb4b4b4.Te6edf3routingErrorTb4b4b4,
Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3packetIdTb4b4b4,
Te6edf3emojis Tff7b72= Te6edf3emptyListTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3replyId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3replyIdTb4b4b4,
Tb4b4b4)
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
T8b949e/**
* Sanitizes a user query for FTS5 by wrapping each token in double quotes. This escapes FTS5 special characters (*,
* -, NEAR, etc.) while still allowing multi-word searches as implicit AND queries.
*/
Tff7b72private Tff7b72fun Td2a8ffsanitizeFtsQueryTb4b4b4(Te6edf3queryTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657String Tff7b72=
Te6edf3queryTb4b4b4.Te6edf3splitTb4b4b4(Ta5d6ff"Ta5d6ff\\Ta5d6ffs+Ta5d6ff"Tb4b4b4.Te6edf3toRegexTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3isNotBlankTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4.Te6edf3joinToStringTb4b4b4(Ta5d6ff"Ta5d6ff Ta5d6ff"Tb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ff\"Tffd700${Tffa657itTb4b4b4.Te6edf3replaceTb4b4b4(Ta5d6ff"\Ta5d6ff"Ta5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ff"Tb4b4b4)Tffd700}Ta5d6ff\"Ta5d6ff" Tb4b4b4}
Tff7b72companion Tff7b72object Tb4b4b4{
Tff7b72private Tff7b72const Tff7b72val Te6edf3CONTACTS_PAGE_SIZE Tff7b72= T79c0ff3T79c0ff0
Tff7b72private Tff7b72const Tff7b72val Te6edf3MESSAGES_PAGE_SIZE Tff7b72= T79c0ff5T79c0ff0
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.4.2 - Generated in 0.24s